package trident.partition;

import org.apache.storm.trident.operation.BaseFilter;
import org.apache.storm.trident.tuple.TridentTuple;

public class ScoreFilter extends BaseFilter {
    @Override
    public boolean isKeep(TridentTuple tuple) {
        return tuple.getIntegerByField("hive") >= 60 && tuple.getIntegerByField("storm") >= 60;
    }
}
